package com.dhcc.consumer.listener.topicListener;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class MessageTopicListener01 {
	@RabbitListener(queues = "topic-queue-01")
	public void listenerSimple(Message message) {
		// message分装了消息
		byte[] body = message.getBody();
		String content = new String(body);
		System.out.println("MessageTopicListener01...msg01 ----->" + content);
	}
}
